type github.com/go-pg/pg/v10.baseDB
67 uses
github.com/go-pg/pg/v10 (current package)
base.go#L14: type baseDB struct {
base.go#L27: func (db *baseDB) PoolStats() *PoolStats {
base.go#L32: func (db *baseDB) clone() *baseDB {
base.go#L33: return &baseDB{
base.go#L43: func (db *baseDB) withPool(p pool.Pooler) *baseDB {
base.go#L49: func (db *baseDB) WithTimeout(d time.Duration) *baseDB {
base.go#L59: func (db *baseDB) WithParam(param string, value interface{}) *baseDB {
base.go#L66: func (db *baseDB) Param(param string) interface{} {
base.go#L70: func (db *baseDB) retryBackoff(retry int) time.Duration {
base.go#L74: func (db *baseDB) getConn(ctx context.Context) (*pool.Conn, error) {
base.go#L99: func (db *baseDB) initConn(ctx context.Context, cn *pool.Conn) error {
base.go#L125: func (db *baseDB) releaseConn(ctx context.Context, cn *pool.Conn, err error) {
base.go#L139: func (db *baseDB) withConn(
base.go#L183: func (db *baseDB) shouldRetry(err error) bool {
base.go#L215: func (db *baseDB) Close() error {
base.go#L221: func (db *baseDB) Exec(query interface{}, params ...interface{}) (res Result, err error) {
base.go#L225: func (db *baseDB) ExecContext(c context.Context, query interface{}, params ...interface{}) (Result, error) {
base.go#L229: func (db *baseDB) exec(ctx context.Context, query interface{}, params ...interface{}) (Result, error) {
base.go#L269: func (db *baseDB) ExecOne(query interface{}, params ...interface{}) (Result, error) {
base.go#L273: func (db *baseDB) ExecOneContext(ctx context.Context, query interface{}, params ...interface{}) (Result, error) {
base.go#L277: func (db *baseDB) execOne(c context.Context, query interface{}, params ...interface{}) (Result, error) {
base.go#L291: func (db *baseDB) Query(model, query interface{}, params ...interface{}) (res Result, err error) {
base.go#L295: func (db *baseDB) QueryContext(c context.Context, model, query interface{}, params ...interface{}) (Result, error) {
base.go#L299: func (db *baseDB) query(ctx context.Context, model, query interface{}, params ...interface{}) (Result, error) {
base.go#L339: func (db *baseDB) QueryOne(model, query interface{}, params ...interface{}) (Result, error) {
base.go#L343: func (db *baseDB) QueryOneContext(
base.go#L349: func (db *baseDB) queryOne(ctx context.Context, model, query interface{}, params ...interface{}) (Result, error) {
base.go#L362: func (db *baseDB) CopyFrom(r io.Reader, query interface{}, params ...interface{}) (res Result, err error) {
base.go#L372: func (db *baseDB) copyFrom(
base.go#L445: func (db *baseDB) CopyTo(w io.Writer, query interface{}, params ...interface{}) (res Result, err error) {
base.go#L454: func (db *baseDB) copyTo(
base.go#L508: func (db *baseDB) Ping(ctx context.Context) error {
base.go#L514: func (db *baseDB) Model(model ...interface{}) *Query {
base.go#L518: func (db *baseDB) ModelContext(c context.Context, model ...interface{}) *Query {
base.go#L522: func (db *baseDB) Formatter() orm.QueryFormatter {
base.go#L526: func (db *baseDB) cancelRequest(processID, secretKey int32) error {
base.go#L543: func (db *baseDB) simpleQuery(
base.go#L562: func (db *baseDB) simpleQueryData(
base.go#L584: func (db *baseDB) Prepare(q string) (*Stmt, error) {
base.go#L588: func (db *baseDB) prepare(
base.go#L612: func (db *baseDB) closeStmt(c context.Context, cn *pool.Conn, name string) error {
db.go#L20: &baseDB{
db.go#L28: func newDB(ctx context.Context, baseDB *baseDB) *DB {
db.go#L41: *baseDB
db.go#L96: *baseDB
db.go#L111: func newConn(ctx context.Context, baseDB *baseDB) *Conn {
hook.go#L75: func (db *baseDB) AddQueryHook(hook QueryHook) {
hook.go#L79: func (db *baseDB) beforeQuery(
hook.go#L113: func (db *baseDB) afterQuery(
hook.go#L128: func (db *baseDB) afterQueryFromIndex(ctx context.Context, event *QueryEvent, hookIndex int) error {
messages.go#L78: func (db *baseDB) startup(
messages.go#L142: func (db *baseDB) enableSSL(c context.Context, cn *pool.Conn, tlsConf *tls.Config) error {
messages.go#L169: func (db *baseDB) auth(
messages.go#L197: func (db *baseDB) logStartupNotice(
messages.go#L236: func (db *baseDB) authCleartext(
messages.go#L249: func (db *baseDB) authMD5(
messages.go#L296: func (db *baseDB) authSASL(
stmt.go#L18: db *baseDB
stmt.go#L26: func prepareStmt(db *baseDB, q string) (*Stmt, error) {
tx.go#L30: db *baseDB
tx.go#L47: func (db *baseDB) Begin() (*Tx, error) {
tx.go#L51: func (db *baseDB) BeginContext(ctx context.Context) (*Tx, error) {
tx.go#L69: func (db *baseDB) RunInTransaction(ctx context.Context, fn func(*Tx) error) error {